﻿using Common.EventBus.EventBusRabbitMQ;

namespace Common.EventBus.EventBusRabbitMQ.Tests
{
    /// <summary>
    /// 消费端，即用于接收数据方
    /// 特别注意：QueueSubscribe要理解什么意思
    /// </summary>
    [QueueSubscribe(Queue = "test.log", ExchangeName = "", ExchangeType = "", RouteKey = "test.log")]
    public class TestLogEventHandler : BaseQueueHandler<TestLogEvent>
    {
        public override async Task Handler(TestLogEvent e)
        {
            await Task.CompletedTask;
            Console.WriteLine($"{e.Id}：{e.Text}");
        }
    }
}